package schedule

import "github.com/beherochuling/beesoft_api/app/helper/net"

func rabbitmqSubscribe() {
	go func() {
		ctx := context.Background()

		endpoint := "mqtt://111.229.207.234:1883"

		net.NewMqtt(ctx).
			Endpoint(endpoint).
			Subscribe()
	}()
}
